package com.hitqz.robot.driver.zmq.protocol.component;


/**
* 观察者
* */
public interface ZMQObservable  {


    /**
    * 添加通知队列
     * @param server
    * */
    void addObserver(Class<?> server);

    /**
    * 删除队列
     * @param server
    * */
    void deleteObserver(Class<?> server);

    /**
     * 通知所有的用于zmq数据
     * @param address
     * @param data
    * */
    void notifyObserver(String address, String type,byte[] data) throws Exception;


    void notifyMoniterTask();

}
